package com.dongecloud.stream;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;

@EnableBinding(MyChannel.class)
public class MsgReceive2 {
   private static Logger logger = LoggerFactory.getLogger(MsgReceive2.class);

    @StreamListener(MyChannel.INPUT)
   public void receive2(Object payload){
        logger.info("receive2:" + payload);
   }
}
